package com.intretech.tj.mqtt.entity;

import io.vertx.mutiny.mqtt.messages.MqttPublishMessage;
import lombok.Getter;

/**
 * 消息信息
 */
@Getter
public class MessageInfo {
    /**
     * 发布者
     */
    private final String clientID;

    /**
     * 原始消息
     */
    private final MqttPublishMessage message;

    public MessageInfo(String clientID, MqttPublishMessage message) {
        this.clientID = clientID;
        this.message = message;
    }
}
